package cn.itcast.sink;

import cn.itcast.util.HbaseUtil;
import org.apache.flink.streaming.api.functions.sink.SinkFunction;
import org.apache.hadoop.hbase.client.Put;

import java.util.List;

/**
 * 通用写入Hbase的操作类
 * 个股、指数、板块
 */
public class SinkHbase implements SinkFunction<List<Put>> {
    /**
     * 开发步骤：
     * 1.创建构造方法
     * 2.执行写入操作
     */

    //1.创建构造方法
    String tableName;
    public SinkHbase(String tableName){
        this.tableName = tableName;
    }

    //2.执行写入操作
    @Override
    public void invoke(List<Put> value, Context context) throws Exception {
        HbaseUtil.putList(tableName,value);
    }
}
